Flink Table/Sql自定义Kudu Sink实战(其它Sink可参考)
DynamicTableSourceFactory或DynamicTableSinkFactory将CatalogTable的metadata,转换成DynamicTableSource或DynamicTableSink的实例数据。:Flink Catalog已有的Flink Table,或在Fli
13、Flink 的table api与sql的基本概念、通用api介绍及入门示例
Apache Flink 有两种关系型 API 来做流批统一处理:Table API 和 SQL。Table API 是用于 Scala 和 Java 语言的查询API,它可以用一种非常直观的方式来组合使用选取、过滤、join 等关系型算子。Flink SQL 是基于 Apache Calcite